Skip to main content

Python mongo

Pymongo文档

Table of Contents​

安装​

 $ python -m pip install pymongo
 $ pip list | grep pymongo
 > pymongo              4.6.1

数据库和集合​

from pymongo import mongoClient

mongo = MongoClient("mongodb://localhost:27017") # 连接 mongo
dbs = mongo.list_database_names()                # 列出所有数据库

db = mongo['db']                                 # 按名称创建/获取数据库(数据库集合中创建元素后才实际创建数据库)
mongo.drop_database('db')                        # 删除数据库


collection = db['student']                       # 按名称创建/获取集合, 类似关系数据库中的表
db.drop_collection('student')                    # 删除集合

collection.rename('person')                      # 重命名集合

集合约束

ASCENDING: 升序
DESCENDING: 降序

from pymongo import ASCENDING

collection.create_index([("index", ASCENDING)])  # 集合按升序索引
collection.create_index([("index", ASCENDING)])  # 集合按降序索引

collection.create_index("index", unique=True)    # 集合按升序索引(默认值), 且 index 字段唯一

collection.create_index([                        # 复合唯一性约束
  ('field1', ASCENDING), ('field2', ASCENDING)],
  unique=True
)

collection.create_index(                         # 过期设定, 过期后自动删除
    [('expire_at', ASCENDING)],
    expireAfterSeconds=3600
)

Add​

insert({key: value})

item = collection.insert_one(dict)               # 插入单个数据
item.inserted_id                                 # 插入数据的 id

collection.insert_one({'id':1, 'name': 'John'})

item = collection.insert_many(iterable[dict])    # 插入多个数据
item.inserted_ids                                # 打印多个插入数据的 id

collection.insert_many([
    {'id': i, 'value': v}
    for i, v in enumerate('abcd')
])

Query​

find({key: {condation: value}})

更新方式含义示例
$eq值等于,{'name': 'John'} name 为 John 的数据
$ne值不等于,{'name': {'$ne': 'John'}} name 不等于 John 的值
$lt, $lte小于, 小于等于{'num': {'$lt': 10}} num 小于 10 的数据
$gt, $gte大于, 大于等于{'num': {'$gte': 10}} num 大于等于 10 的数据
$in在范围内{'index': {'$in': [1, 2, 3]}} index 的值是 1, 2, 3 的数据
$regex符合正则表达式{'name': {'$regex': '^J'}} name 符合正则的数据

逻辑与: {'num': {'$gt':10, '$lt': 20}} num 大于 10 且小于 20 的数据
逻辑或: {'$or': [{'name': 'John'}, {'index': 3}]} name 为 John 或 index 为 3 的数据

iten = collection.find_one(dict)                   # 查询单个数据 -> dict
data = collection.find_one({'id': 1})

items = collection.find(dict)                      # 查询多个数据 -> generation(仅能遍历一次)
items.count()                                      # 查询计数
for data in collection.find({'version': 'v1'}):
    print(data)

Update​

update(query, update)
query 与查询一致, update 有多种方式

更新方式含义示例
$set更新字段{'$set': {'name': 'John'}} index 为 3 的数据, name 字段改为 John
$inc字段值自增(可负数){'$inc': {'n': 1}} index 3 的数据, n 字段加 1
$unset删除字段{'$unset': {'name': ""}} 删除 name 字段
$rename字段重命名{'$rename': {'name': 'username'}} 重命名 name 字段
$push数组结尾添加值{'$push': {'person': 'lily'}} person 结尾添加 lily 元素
$pop数组弹出一个元素{'$pop': {'person': 1}} 1 表示末尾, -1 表示开头弹出
$currentDate更新字段为当前日期{'$currentDate': {'update': True}} 日期更新

collection.replace_one(dict, dict)               # 数据替换

item = collection.update_one(dict, dict)         # 更新指定单个数据的字段
item.matched_count                               # 匹配数量
item.modified_count                              # 修改数量
collection.update_one({'id': 1},{'$set': {'version', 'v2'}})

items = collection.update_many(dict, dict)       # 修改指定的所有数据字段
collection.update_one({'version': 'v1'},{'$set': {'version', 'v2'}})
collection.update_many(dict, dict)               # 数据替换, 原数据除 _id 外全删除, 替换为新的数据

collection.find_one({'index': 1})
> {'_id': ObjectId('54f4c5befba5220aa4d6dee7'), 'index': 1, 'name': 'John'}

collection.replace_one({'index': 1}, {'x': 2})
collection.find_one({'x': 2})
> {'_id': ObjectId('54f4c5befba5220aa4d6dee7'), 'x': 2}

Delete​

update({key: {condation: value}}) 与 query 一致

item = collection.delete_one(dict)               # 删除匹配的单个数据
item.deleted_count                               # 删除数量
collection.delete_one({'index': 1})

collection.delete_many(dict)                     # 删除匹配的所有数据
collection.delete_many({'age': {'$gt': 18}})